package ms.opentracing.jaeger.conf;

import ms.opentracing.jaeger.doamin.PersonA;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.function.Consumer;

@Configuration
public class CloudStreamConfiguration {

    @Bean
    public Consumer<PersonA> messageCenter(){
        return t->{
            System.out.println(t);
        };
    }

}
